package com.ruoqing.core.fallback.callback;

import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.producer.SendCallback;
import org.apache.rocketmq.client.producer.SendResult;

/**
	* @author YaoXian
	* @title: MySendCallback
	* @projectName ruoxi-blog
	* @description: 若兮微服务 - 核心模块 - 消息队列发送消息回调函数
	* @date 2020-11-28 21:15
	*/
@Slf4j
public class MySendCallback implements SendCallback {
		public void onSuccess(SendResult sendResult) {
				log.info("发送消息成功!");
		}
		
		public void onException(Throwable throwable) {
				log.info("发送消息失败!");
		}
}
